unsubscribed.set(true);
}
};
Observable.just(1).doOnDispose(unsubscribeAction)
.takeLast(1).subscribe();
assertTrue(unsubscribed.get());
}
unsubscribed.set(true);
}
};
Observable.just(1)
.concatWith(Observable.<Integer>never())
.doOnDispose(unsubscribeAction)
.takeLast(1)
.subscribe()